import asyncio


async def run():
    print('协程1开始')
    await asyncio.sleep(2)
    print('线程1结束')
    return '返回值'


def call_back(f):
    print(f.result())  # 获取返回值


# 创建协程对象
coroutine = run()
# 创建任务
task = asyncio.ensure_future(coroutine)
# 给任务添加 回调函数
task.add_done_callback(call_back)
# 创建事件循环
loop = asyncio.get_event_loop()
# 将任务放到事件循环中
loop.run_until_complete(task)
